package com.shaozi.nc.io.mq;

import org.apache.log4j.Logger;

import com.shaozi.data.mq.protocol.ConnectionBuilder;
import com.shaozi.data.mq.protocol.stomp.StompTextProducer;
import com.shaozi.nc.data.model.CompanyInfoModel;


public class CompanyInfoChangeEventProducer extends StompTextProducer {

	private final Logger logger = Logger.getLogger(CompanyInfoChangeEventProducer.class);

	public CompanyInfoChangeEventProducer(ConnectionBuilder connBuilder) {
		super(connBuilder);
	}

	public void pushMsg(CompanyInfoModel bean) {
		if (bean == null) {
			logger.error("CompanyInfoModel is null, can not send to mq");
			return;
		}

		sendObj("com.push.companyinfo.changed", bean);
	}
}
